package com.weng.bigdata.core.mq.config;

/**
 * MQ Topic配置，@KafkaListener 的配置要求topic名称必须是final的字符串
 *
 * @author wengzhonghui
 * @date: 2021-06-25 17:15:52
 */
public class MqTopicConstants {


    public static final String EXECUTE_SCRIPT_STATUS = "execute_script_status";

    public static final String DATA_COLLECT_STATE_EVENT = "data_collect_state_event";

    public static final String DATA_COLLECT_METRICS_EVENT = "data_collect_metrics_event";

    public static final String COLLECT_TASK_STATUS = "collect_task_status";


}